Spring Redis 单数据源实战配置 |
您所在的位置：网站首页 › redis hostname › Spring Redis 单数据源实战配置 |
|
redis项目实战配置
[TOC] 主pom.xml文件 2.9.0 1.7.2.RELEASE 2.0.2.RELEASE redis.clients jedis ${redis.jedis.version} org.springframework.data spring-data-redis ${spring-data-redis.version} org.springframework.session spring-session-data-redis ${spring-session-data-redis.version} 复制代码 一、web层redis配置及使用 web层 pom.xml 2.0.8.RELEASE redis.clients jedis org.springframework.session spring-session-data-redis org.springframework.data spring-data-redis ${spring-data-redis.version} 复制代码 redis.propertiesweb层 #jedisConnectionFactory #redis.hostname=192.168.1.81 #redis.hostname=192.168.1.115 redis.hostname=127.0.0.1 redis.port=6379 #客户端超时时间单位是毫秒 默认是2000 redis.timeout=3000 redis.usePool=true #jedisPoolConfig #连接池的最大数据库连接数 redis.maxTotal=100 #最大空闲数 redis.maxIdle=32 #最大建立连接等待时间。如果超过此时间将接到异常 redis.maxWait=30000 #是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个 redis.testOnBorrow=true #session过期时间，单位秒 redis.session.timeout=600 复制代码 spring-redis.xmlweb层 复制代码 spring-common.xmlweb层 复制代码 web.xml gxtz-server-web index.html springSessionRepositoryFilter org.springframework.web.filter.DelegatingFilterProxy springSessionRepositoryFilter /* org.springframework.web.context.ContextLoaderListener contextConfigLocation classpath:META-INF/spring/spring-common.xml org.springframework.web.context.request.RequestContextListener springmvc org.springframework.web.servlet.DispatcherServlet contextConfigLocation classpath:META-INF/spring/spring-mvc.xml 1 springmvc / 复制代码 工具类util文件下RedisUtilRedisUtil.java package com.dist.util; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.util.CollectionUtils; import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.TimeUnit; /** * redisTemplate封装 * * @author [email protected] */ public class RedisUtil { private RedisTemplate redisTemplate; public RedisUtil(RedisTemplate redisTemplate) { this.redisTemplate = redisTemplate; } /** * 指定缓存失效时间 * @param key 键 * @param time 时间(秒) * @return */ public boolean expire(String key,long time){ try { if(time>0){ redisTemplate.expire(key, time, TimeUnit.SECONDS); } return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 根据key 获取过期时间 * @param key 键 不能为null * @return 时间(秒) 返回0代表为永久有效 */ public long getExpire(String key){ return redisTemplate.getExpire(key,TimeUnit.SECONDS); } /** * 判断key是否存在 * @param key 键 * @return true 存在 false不存在 */ public boolean hasKey(String key){ try { return redisTemplate.hasKey(key); } catch (Exception e) { e.printStackTrace(); return false; } } /** * 删除缓存 * @param key 可以传一个值 或多个 */ @SuppressWarnings("unchecked") public void del(String ... key){ if(key!=null&&key.length>0){ if(key.length==1){ redisTemplate.delete(key[0]); }else{ redisTemplate.delete(CollectionUtils.arrayToList(key)); } } } //============================String============================= /** * 普通缓存获取 * @param key 键 * @return 值 */ public Object get(String key){ return key==null?null:redisTemplate.opsForValue().get(key); } /** * 普通缓存放入 * @param key 键 * @param value 值 * @return true成功 false失败 */ public boolean set(String key,Object value) { try { redisTemplate.opsForValue().set(key, value); return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 普通缓存放入并设置时间 * @param key 键 * @param value 值 * @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期 * @return true成功 false 失败 */ public boolean set(String key,Object value,long time){ try { if(time>0){ redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS); }else{ set(key, value); } return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 递增 * @param key 键 * @param delta 要增加几(大于0) * @return */ public long incr(String key, long delta){ if(delta0){ expire(key, time); } return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 删除hash表中的值 * @param key 键 不能为null * @param item 项 可以使多个 不能为null */ public void hdel(String key, Object... item){ redisTemplate.opsForHash().delete(key,item); } /** * 判断hash表中是否有该项的值 * @param key 键 不能为null * @param item 项 不能为null * @return true 存在 false不存在 */ public boolean hHasKey(String key, String item){ return redisTemplate.opsForHash().hasKey(key, item); } /** * hash递增 如果不存在,就会创建一个 并把新增后的值返回 * @param key 键 * @param item 项 * @param by 要增加几(大于0) * @return */ public double hincr(String key, String item,double by){ return redisTemplate.opsForHash().increment(key, item, by); } /** * hash递减 * @param key 键 * @param item 项 * @param by 要减少记(小于0) * @return */ public double hdecr(String key, String item,double by){ return redisTemplate.opsForHash().increment(key, item,-by); } //============================set============================= /** * 根据key获取Set中的所有值 * @param key 键 * @return */ public Set sGet(String key){ try { return redisTemplate.opsForSet().members(key); } catch (Exception e) { e.printStackTrace(); return null; } } /** * 根据value从一个set中查询,是否存在 * @param key 键 * @param value 值 * @return true 存在 false不存在 */ public boolean sHasKey(String key,Object value){ try { return redisTemplate.opsForSet().isMember(key, value); } catch (Exception e) { e.printStackTrace(); return false; } } /** * 将数据放入set缓存 * @param key 键 * @param values 值 可以是多个 * @return 成功个数 */ public long sSet(String key, Object...values) { try { return redisTemplate.opsForSet().add(key, values); } catch (Exception e) { e.printStackTrace(); return 0; } } /** * 将set数据放入缓存 * @param key 键 * @param time 时间(秒) * @param values 值 可以是多个 * @return 成功个数 */ public long sSetAndTime(String key,long time,Object...values) { try { Long count = redisTemplate.opsForSet().add(key, values); if(time>0) { expire(key, time); } return count; } catch (Exception e) { e.printStackTrace(); return 0; } } /** * 获取set缓存的长度 * @param key 键 * @return */ public long sGetSetSize(String key){ try { return redisTemplate.opsForSet().size(key); } catch (Exception e) { e.printStackTrace(); return 0; } } /** * 移除值为value的 * @param key 键 * @param values 值 可以是多个 * @return 移除的个数 */ public long setRemove(String key, Object ...values) { try { Long count = redisTemplate.opsForSet().remove(key, values); return count; } catch (Exception e) { e.printStackTrace(); return 0; } } //===============================list================================= /** * 获取list缓存的内容 * @param key 键 * @param start 开始 * @param end 结束 0 到 -1代表所有值 * @return */ public List lGet(String key, long start, long end){ try { return redisTemplate.opsForList().range(key, start, end); } catch (Exception e) { e.printStackTrace(); return null; } } /** * 获取list缓存的长度 * @param key 键 * @return */ public long lGetListSize(String key){ try { return redisTemplate.opsForList().size(key); } catch (Exception e) { e.printStackTrace(); return 0; } } /** * 通过索引 获取list中的值 * @param key 键 * @param index 索引 index>=0时， 0 表头，1 第二个元素，依次类推；index 0) { expire(key, time); } return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 将list放入缓存 * @param key 键 * @param value 值 * @return */ public boolean lSet(String key, List value) { try { redisTemplate.opsForList().rightPushAll(key, value); return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 将list放入缓存 * @param key 键 * @param value 值 * @param time 时间(秒) * @return */ public boolean lSet(String key, List value, long time) { try { redisTemplate.opsForList().rightPushAll(key, value); if (time > 0) { expire(key, time); } return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 根据索引修改list中的某条数据 * @param key 键 * @param index 索引 * @param value 值 * @return */ public boolean lUpdateIndex(String key, long index,Object value) { try { redisTemplate.opsForList().set(key, index, value); return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 移除N个值为value * @param key 键 * @param count 移除多少个 * @param value 值 * @return 移除的个数 */ public long lRemove(String key,long count,Object value) { try { Long remove = redisTemplate.opsForList().remove(key, count, value); return remove; } catch (Exception e) { e.printStackTrace(); return 0; } } } 复制代码 web-Controller层调用缓存ResourceController.java package com.dist.web; import com.dist.common.LocalTomcatService; import com.dist.common.MongoService; import com.dist.common.RemoteTomcatService; import com.dist.constant.Constants; import com.dist.dto.ResourceFileDto; import com.dist.exception.illegalParameterException; import com.dist.interfaces.IResourceFileService; import com.dist.response.Result; import com.dist.response.ResultUtil; import com.dist.thread.DistThreadManager; import com.dist.util.MultipartFileUtil; import com.dist.util.RedisUtil; import com.dist.utils.ObjectUtil; import com.dist.vo.ResourceFileVo; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiParam; import lombok.extern.slf4j.Slf4j; import net.sf.jmimemagic.Magic; import net.sf.jmimemagic.MagicMatch; import org.apache.commons.lang3.StringUtils; import org.dozer.Mapper; import org.springframework.http.HttpHeaders; import org.springframework.http.HttpStatus; import org.springframework.http.MediaType; import org.springframework.http.ResponseEntity; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import javax.annotation.Resource; import java.io.IOException; import java.io.OutputStream; import java.net.URLEncoder; import java.util.ArrayList; import java.util.List; /** * 资源文件 * * @author [email protected] */ @RestController @Api(tags = "ResourceController",description = "资源文件") @Slf4j public class ResourceController extends BaseController { @Resource private RedisUtil redisUtil; /** * 更新redis缓存中资源文件 * @param id * @param resourceFileDto */ private void updateToRedis(String id, ResourceFileDto resourceFileDto) { redisUtil.set(id, resourceFileDto); //普通缓存放入 redisUtil.expire(id, Constants.REDIS_DEFULT_EXPIRE);//用全局常量配置-指定缓存失效时间 } /** * 从redis缓存中取资源文件 * @param id * @return */ private ResourceFileDto getFromRedis(String id) { boolean exist = redisUtil.hasKey(id); if (exist) { ResourceFileDto resourceFileDto = (ResourceFileDto) redisUtil.get(id); return resourceFileDto; } return null; } /** * 从redis中删除缓存数据 * @param id */ private void deleteFromRedis(String id) { boolean exist = redisUtil.hasKey(id); if (exist) { redisUtil.del(id); } } } 复制代码 web全局常量Constants.java package com.dist.constant; /** * 全局常量 * * @author [email protected] */ public abstract class Constants { public static final long REDIS_DEFULT_EXPIRE = 30 * 60 * 1000; // redis默认有效时间30分钟 } 复制代码 二、service层redis配置及使用service层未使用 service层 redis.properties #jedisConnectionFactory #redis.hostname=192.168.1.115 #redis.hostname=192.168.1.81 redis.hostname=127.0.0.1 redis.port=6379 #客户端超时时间单位是毫秒 默认是2000 redis.timeout=3000 redis.usePool=true #jedisPoolConfig #连接池的最大数据库连接数 redis.maxTotal=100 #最大空闲数 redis.maxIdle=32 #最大建立连接等待时间。如果超过此时间将接到异常 redis.maxWait=30000 #是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个 redis.testOnBorrow=true #缓存有效时间30分钟(60 * 30 = 1800秒) cache.timeout=1800 #缓存刷新时间10分钟 cache.refresh=600 复制代码 pom.xml 1.7.2.RELEASE redis.clients jedis org.springframework.data spring-data-redis ${spring-data-redis.version} 复制代码 spring-redis.xml 复制代码 spring-common.xml 复制代码 service层web.xml gxtz-server-service org.springframework.web.context.ContextLoaderListener contextConfigLocation classpath:META-INF/spring/spring-common.xml 复制代码 |
| CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3 |